
import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.mapreduce.Reducer;

import java.io.IOException;

public class RiskPredictionReducer extends Reducer<IotData, NullWritable, IotData, NullWritable> {
	@Override
	protected void reduce(IotData key, Iterable<NullWritable> values, Context context) throws IOException, InterruptedException {
		for (NullWritable value : values) {
			context.write(key, value);
		}
	}
}
